package com.xqq.threadpool;

import lombok.extern.slf4j.Slf4j;

import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

@Slf4j
public class ThreadPool {
//    public static ThreadPoolExecutor pathPlanPool = new ThreadPoolExecutor(3, 5, 1, TimeUnit.MINUTES,
//            new LinkedBlockingQueue<>(1000), (r, executor) -> log.error("CommonPool任务队列已经满，丢弃后续任务！"));
//
//    public static ThreadPoolExecutor trackMockPool = new ThreadPoolExecutor(10, 30, 1, TimeUnit.MINUTES,
//            new LinkedBlockingQueue<>(1000), (r, executor) -> log.error("TrackMockPool任务队列已经满，丢弃后续任务！"));
//
//    public static ScheduledThreadPoolExecutor switchPathMockPool = new ScheduledThreadPoolExecutor(10,
//            (r, executor) -> log.error("ScheduledPool队列已满，丢弃后续任务！"));
//
//    public static ThreadPoolExecutor commonPool = new ThreadPoolExecutor(20, 100, 2, TimeUnit.MINUTES,
//            new LinkedBlockingQueue<>(1000), (r, executor) -> log.error("CommonPool任务队列已经满，丢弃后续任务！"));
//
//    public static ThreadPoolExecutor layerPool = new ThreadPoolExecutor(20, 100, 2, TimeUnit.MINUTES,
//            new LinkedBlockingQueue<>(1000), (r, executor) -> log.error("LayerPool任务队列已经满，丢弃后续任务！"));

}
